2f3c5b85bcf0a4ac474c1350dc0a74e88bd77e87,clustered/server/src/main/java/org/ehcache/clustered/server/store/ClusterTierActiveEntity.java,ClusterTierActiveEntity,clearClientTrackedAtReconnectComplete,#,568
Before Change
private void clearClientTrackedAtReconnectComplete() {
if (!reconnectComplete.get()) {
if (reconnectComplete.compareAndSet(false, true)) {
stateService.getClientMessageTracker(storeIdentifier).reconcileTrackedClients(getTrackedClients().collect(toSet()));
}
}
}
After Change
private void clearClientTrackedAtReconnectComplete() {
if (!reconnectComplete.get()) {
if (reconnectComplete.compareAndSet(false, true)) {
ClientMessageTracker clientMessageTracker = stateService.getClientMessageTracker(storeIdentifier);
if (clientMessageTracker != null) {
clientMessageTracker.reconcileTrackedClients(getTrackedClients().collect(toSet()));
}
}